package com.flinkjar.flinkjardemo.bean;

import io.debezium.data.Envelope;


import java.io.Serializable;



public class BaseBean implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * 操作类型, 默认是新增
     */
    public Envelope.Operation operation = Envelope.Operation.CREATE;


    public Envelope.Operation getOperation() {
        return operation;
    }

    public void setOperation(Envelope.Operation operation) {
        this.operation = operation;
    }

    @Override
    public String toString() {
        return "BaseBean{" +
                "operation=" + operation +
                '}';
    }
}
